package com.lefeng.cockpit.datax.dao;

import com.lefeng.cockpit.common.bean.po.job.JobInfoPO;

import java.util.Date;
import java.util.List;

public interface JobInfoDao {
    JobInfoPO loadById(int jobId);

    void updateLastHandleCode(int jobId, int lastHandleCode);

    void incrementIdUpdate(int jobId, Long incStartId);

    void incrementTimeUpdate(int jobId, Date triggerTime);

    List<JobInfoPO> scheduleJobQuery(long l, int preReadCount);

    void scheduleUpdate(JobInfoPO jobInfo);
}
